import fun.lumia.common.SparkTool
import org.apache.spark.streaming.StreamingContext

object testKafka extends SparkTool {
  /**
   * 在run方法里面编写spark业务逻辑
   */
  override def run(args: Array[String]): Unit = {
  }

  /**
   * 初始化spark配置
   *  conf.setMaster("local")
   */
  override def init(): Unit = {
    conf.setAppName("testKafka")
    conf.setMaster("local[4]")
  }
}
